package com.exchange.websocket.common.exchangeutils;


import com.exchange.websocket.common.huobi.WebSocketService;
import com.exchange.websocket.common.huobi.impl.HuobiBuissnesWebSocketServiceImpl;
import com.exchange.websocket.common.huobi.impl.WebSoketClient;
import com.exchange.websocket.common.utils.redis.RedisUtil;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

/**
 * WebSocket API使用事例
 *
 * @author okcoin
 */
@Component
public class HuobiWebsocketClient {


    public void startClient(String url,RedisUtil redisUtil) {
        // 订阅消息处理类,用于处理WebSocket服务返回的消息
        WebSocketService service = new HuobiBuissnesWebSocketServiceImpl();
        // WebSocket客户端
        WebSoketClient client = new WebSoketClient(url, service,redisUtil);
        // 启动客户端
        client.start();
        // 添加订阅
        client.addChannelHuobi("market.btcusdt.depth.step1");
        // 删除定订阅
        // client.removeChannelOK("ok_sub_spot_bch_btc_ticker");
    }
}
